/*
 * FileName: HbaseConfiguration.java
 * Author:   zzw
 * Date:     2018年05月23日
 * Description:
 */
package com.chezhibao.configuration;

import org.apache.hadoop.hbase.HBaseConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.hadoop.hbase.HbaseTemplate;

/**
 * 〈Hbase配置〉<br>
 * 〈Hbase配置〉
 *
 * @author zzw
 * @see [相关类/方法]（可选）
 * @since [产品/模块版本]（可选）
 */
@Configuration
public class HbaseConfiguration {

    @Bean
    public HbaseTemplate hbaseTemplate(HbaseProperties hbaseProperties) {
        HbaseTemplate hbaseTemplate = new HbaseTemplate();
        org.apache.hadoop.conf.Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum", hbaseProperties.getQuorum());
        conf.set("hbase.zookeeper.port", hbaseProperties.getPort());
        hbaseTemplate.setConfiguration(conf);
        hbaseTemplate.setAutoFlush(true);
        return hbaseTemplate;
    }
}